package org.tao.lightningmq.broker.core;

import java.util.HashMap;
import java.util.Map;

/**
 * @Author lht
 * @date 2025/1/3 - 16:31
 * @description:
 */
public class CommitLogMMapFileModelManager {

    /**
     * key: topic名称
     * value: CommitLogMMapFileModel
     */
    private final Map<String, CommitLogMMapFileModel> mMapFileModelMap = new HashMap<>(16);

    public CommitLogMMapFileModel get(String topic) {
        return mMapFileModelMap.get(topic);
    }

    public void put(String topic, CommitLogMMapFileModel commitLogMMapFileModel) {
        mMapFileModelMap.put(topic, commitLogMMapFileModel);
    }

}
